package work.chenxr.redis.receiver;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 * @Author Chenxr
 * @Date 2023/09/11
 * @Description 消息接收器
 */
@Slf4j
@Component
public class RedisMessageReceiver {
    /**
     * 普通消息接收器
     *
     * @param message 消息
     */
    public void receiveMessage(String message) {
        log.info("接收到普通消息：{}", message);
        // 业务逻辑
        log.info("普通消息业务逻辑处理中...");
        log.info("普通消息业务逻辑处理完毕！");
    }

    /**
     * 定时消息接收器
     *
     * @param message 消息
     */
    public void receiveTimingMessage(String message) {
        log.info("接收到定时消息：{}", message);
        // 业务逻辑
        log.info("定时消息业务逻辑处理中...");
        log.info("定时消息业务逻辑处理完毕！");
    }
}
